package com.ds.lens.manager.controller;


import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@Slf4j
@RestController
@RequestMapping(value = "/manager")
public class RuleJobMgt {
//
//    @Autowired
//    private Rules rules;
//
//
//    /**
//     * 根据规则ID启动后台对应job
//     *
//     * @return
//     */
//    @RequestMapping(value = "/ruleJob/start", method = RequestMethod.POST)
//    public BaseOutVO startRuleJobById(@RequestBody @Validated RuleInfo ruleInfo) {
//
//        try {
//            int flag = rules.runByRuleId(ruleInfo.getId().toString(),ruleInfo.getAlarmName());
//            if(flag == 0){
//                return VOFactory.getSuccessBaseOutVO();
//            }else{
//                return VOFactory.getBaseOutVO(VoMessageEnum.FAILED.getCode(), VoMessageEnum.FAILED.getMessage());
//            }
//        } catch (Exception e) {
//            log.error("启动规则job失败",e);
//            return VOFactory.getBaseOutVO(VoMessageEnum.FAILED.getCode(), VoMessageEnum.FAILED.getMessage());
//        }
//
//
//    }
//
//    /**
//     * 根据规则ID停止后台对应job
//     *
//     * @return
//     */
//    @RequestMapping(value = "/ruleJob/stop", method = RequestMethod.POST)
//    public BaseOutVO stopRuleJobById(@RequestBody @Validated RuleInfo ruleInfo) {
//        try {
//            int flag = rules.stopByRuleId(ruleInfo.getId().toString(),ruleInfo.getAlarmName());
//            if(flag == 0){
//                return VOFactory.getSuccessBaseOutVO();
//            }else{
//                return VOFactory.getBaseOutVO(VoMessageEnum.FAILED.getCode(), VoMessageEnum.FAILED.getMessage());
//            }
//        } catch (Exception e) {
//            log.error("停止规则job失败",e);
//            return VOFactory.getBaseOutVO(VoMessageEnum.FAILED.getCode(), VoMessageEnum.FAILED.getMessage());
//        }
//    }
//
//    /**
//     * 获取所有flink平台中的job
//     *
//     * @return
//     */
//    @RequestMapping(value = "/ruleJob/getAllFlinkJob", method = RequestMethod.GET)
//    public BaseOutVO getAllFlinkJob() {
//        return VOFactory.getSuccessBaseOutVO(rules.getFlinkJobs());
//    }

}
